package com.xzy.springboot;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class stream_8801 {


    public static void main(String[] args) {
        SpringApplication.run(stream_8801.class,args);

    }
    /*stream是有关mq的技术栈(主要是为了规避不同mq的底层差异,使用统一api完成消息队列,类似数据库连接池)*/



    /*使用步骤(消息生产者)
    * 1在所需发送消息的类中开启注解@EnableBinding(Source.class)
    * org.springframework.cloud.stream.messaging.Source;
    * 2开启后容器中会有MessageChannel对象  注入该对象
    * org.springframework.integration.support.MessageBuilder
    * 3.builder构建消息MessageBuilder.withPayload(具体消息).build()
    * 4通过channel发送  output.send(Message<T>)
    * */
}
